package com.websocket.config.originWebsocket.anno;

import javax.websocket.*;

/**
 * @作者: 林江
 * @创建时间: 2023/12/18
 * @功能:
 */
//@Component
//@ServerEndpoint("/ws")
public class MyWebSocketEndpoint {

    /**
     * 链接成功调用的方法
     */
    @OnOpen
    public void onOpen(Session session) {
        System.out.println("【websocket消息】有新的连接,sessionId=" + session.getId());
    }

    /**
     * 链接关闭调用的方法
     */
    @OnClose
    public void onClose() {
        System.out.println("【websocket消息】连接断开");
    }

    /**
     * 收到客户端消息后调用的方法
     *
     * @param message
     * @param session
     */
    @OnMessage
    public void onMessage(String message) {
        System.out.println("【websocket消息】收到客户端消息:" + message);
    }

    /**
     * 发送错误时的处理
     *
     * @param session
     * @param error
     */
    @OnError
    public void onError(Session session, Throwable error) {
        System.out.println("用户错误,原因:" + error.getMessage());
        error.printStackTrace();
    }
}
